package com.hhxy.utils;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

/**
 * @author ghp
 * @date 2023/2/22
 * @title
 * @description 此类为
 */
public class RabbitMqUtil {

    /**
     * 获取信道
     * @return
     * @throws Exception
     */
    public static Channel getChannel() throws Exception {
        // 1、创建一个连接工厂对象，用于创建连接
        ConnectionFactory factory = new ConnectionFactory();
        // 2、配置连接信息
        factory.setHost("192.168.88.136"); // 设置工厂IP，用于连接RabbitMQ
        factory.setUsername("admin"); // 设置用户名
        factory.setPassword("123"); // 设置密码
        // 3、创建连接（这一步需要抛异常，比如IP对应的RabbitMQ不存在或者说密码账号错误）
        Connection connection = factory.newConnection();
        // 4、获取信道
        Channel channel = connection.createChannel();
        // 5、返回获取到的信道
        return channel;
    }
}
